package org.jpush.core;

/**
 * 
 * 
 * @author Lei Wang
 *
 */
public abstract class PhysicalConnectionEventQueue
{
	public abstract boolean create();
	public abstract void destroy();
	
	public abstract boolean register(PhysicalConnection connection);
	
	// Send a signal then all the worker who is waiting for 
	// getEvent will get a instant result so that they will not
	// be blocked forever
	public abstract void postTerminateSignal();
	
	public abstract PhysicalConnectionEvent getEvent();
}
